package test.ground.kafka;

import com.wang.tool.monitor.LinkLogUtil;
import com.wang.tool.monitor.aop.Monitor;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service  
public class KafkaConsumerService {

    @KafkaListener(topics = "tool_test", groupId = "tool_test_group")
    @Monitor
    public void consume(String message) {
        LinkLogUtil.info("consume message"+message);
    }
}